package org.apache.spark.sql.execution.datasources.rest

import org.apache.spark.{Partition, SparkContext}

import scala.collection.mutable.ArrayBuffer

class RestPartition(sc: SparkContext, params: Map[String, String], idx: Int) extends Partition {
  override def index: Int = this.idx
}

object RestPartition {
  def computePartition(sc: SparkContext, params: Map[String, String]): Array[Partition] = {
    val buff = new ArrayBuffer[Partition]()
    buff.append(new RestPartition(sc, params, 0))
    buff.toArray
  }
}
